# 导入websocket-client库
import websocket


# 定义on_message事件回调函数
def on_message(ws_app, message):
    print("接收到服务器响应：", message)


# 定义on_error事件回调函数
def on_error(ws_app, error):
    print(error)


# 定义on_open事件回调函数
def on_open(ws_app):
    print('已连接到WebSocket服务器')


# 定义on_close事件回调函数
def on_close(ws_app):
    print('已关闭和WebSocket服务器的连接')


# 实例化一个ws客户端
url = "ws://echo.websocket.events"
ws = websocket.WebSocketApp(
    url=url,
    on_open=on_open,
    on_message=on_message,
    on_error=on_error,
    on_close=on_close,
)

# 开启长连接，开始监听
ws.run_forever()

# 发送信息
ws.send("hello!")

# 关闭连接
ws.close()
